var websock = null;
let rec; //断线重连后，延迟5秒重新创建WebSocket连接  rec用来存储延迟请求的代码
let isConnect = false; //连接标识 避免重复连接
let isAuto = false; // 是否主动断开连接
let checkMsg = "heartbeat"; //心跳发送/返回的信息 服务器和客户端收到的信息内容如果如下 就识别为心跳信息 不要做业务处理
let ws = "ws://123.56.248.50:9080/ws";
var globalCallback = function () {};

let createWebSocket = () => {
    try {
        websock = new WebSocket(ws);
        initWebSocket(); //初始化websocket连接
    } catch (e) {
        console.log("尝试创建连接失败");
        reConnect(); //如果无法连接上webSocket 那么重新连接！可能会因为服务器重新部署，或者短暂断网等导致无法创建连接
    }
};

//定义重连函数
let reConnect = () => {
    console.log("尝试重新连接");
    //如果已经连上就不在重连了
    if (isAuto) return
    rec && clearTimeout(rec);
    rec = setTimeout(function () { // 延迟5秒重连  避免过多次过频繁请求重连
        createWebSocket();
    }, 5000);
};
//设置关闭连接
let closeWebSocket = () => {
    isAuto = true;
    if (websock == null) return
    websock.close();
    console.log('WebSocket关闭')
};
//心跳设置
var heartCheck = {
    timeout: 20000, //每段时间发送一次心跳包 这里设置为20s
    timeoutObj: null, //延时发送消息对象（启动心跳新建这个对象，收到消息后重置对象）

    start: function () {
        if (isAuto) return
        this.timeoutObj = setInterval(function () {
            if (isConnect) websocketsend({type:"1"});
        }, this.timeout);
    },

    reset: function () {
        clearTimeout(this.timeoutObj);
        this.start();
    }
};

// 初始化websocket
function initWebSocket() {
    isAuto = false;
    // ws地址 -->这里是你的请求路径
    // let uName = localStorage.getItem("uName")
    // websock = new WebSocket(ws)
    websock.onmessage = function (e) {
        if (isAuto) return
        websocketonmessage(e)
    }
    websock.onclose = function (e) {
        if (isAuto) return
        websocketclose(e)
    }
    websock.onopen = function () {
        if (isAuto) return
        websocketOpen()
        heartCheck.start();
        // 如果缓存中存在，直接注册
    }

    // 连接发生错误的回调方法
    websock.onerror = function () {
        if (isAuto) return
        console.log('WebSocket连接发生错误')
        isConnect = false; //连接断开修改标识
        reConnect(); //连接错误 需要重连
    }
}

// 实际调用的方法
function sendSock(agentData, callback) {
    globalCallback = callback
    if (websock.readyState === websock.OPEN) {
        // 若是ws开启状态
        websocketsend(agentData)
    } else if (websock.readyState === websock.CONNECTING) {
        // 若是 正在开启状态，则等待1s后重新调用
        setTimeout(function () {
            sendSock(agentData, callback)
        }, 1000)
    } else {
        // 若未开启 ，则等待1s后重新调用
        setTimeout(function () {
            sendSock(agentData, callback)
        }, 1000)
    }
}

function getSock(callback) {
    globalCallback = callback
}
// 数据接收
function websocketonmessage(e) {
    let s = decodeUnicode(e.data);
    let O_o = JSON.parse(s)
    if (!O_o) {
        heartCheck.reset();
    } else {
        if (O_o.msg == "open success") {
            // sessionStorage.setItem("wid", O_o.wid);
        } else {
            globalCallback(O_o);
        }
    }
    // globalCallback(JSON.parse(e.data))
    function decodeUnicode(str) {
        str = str.replace(/\\/g, "%");
        //转换中文
        str = unescape(str);
        //将其他受影响的转换回原来
        str = str.replace(/%/g, "\\");
        //对网址的链接进行处理
        str = str.replace(/\\/g, "");
        return str;
    }
}

// 数据发送
function websocketsend(agentData) {
    if(websock.readyState != websock.OPEN){
        return false;
    }
    websock.send(JSON.stringify(agentData))
}

// 关闭
function websocketclose(e) {
    isConnect = false ; //断开后修改标识
    console.log('connection closed (' + e.code + ')')
    reConnect(); //连接错误 需要重连
}

// 创建 websocket 连接
function websocketOpen(e) {
    isConnect = true
    let userId = localStorage.getItem('userId');
    if (userId != null && userId != "") {
        websocketsend({type:"2",data:userId});
    }
    console.log('连接成功')
}

// initWebSocket()

// 将方法暴露出去
export {
    sendSock,
    getSock,
    createWebSocket,
    initWebSocket,
    closeWebSocket
}
